ef249becdc78394e1a4a6ea05735e80bae8f6477,hadoop/src/main/java/water/hadoop/h2omapper.java,EmbeddedH2OConfig,fetchFlatfile,#,166
Before Change
DriverToMapperMessage msg2 = new DriverToMapperMessage();
msg2.read(s);
if (msg2.getType() != DriverToMapperMessage.TYPE_FETCH_FLATFILE_RESPONSE) {
Log.err("DriverToMapperMessage type unrecognized");
throw new Exception ("DriverToMapperMessage type unrecognized");
}
s.close();
After Change
if (type != DriverToMapperMessage.TYPE_FETCH_FLATFILE_RESPONSE) {
int typeAsInt = (int)type & 0xff;
String str = new String("DriverToMapperMessage type unrecognized (" + typeAsInt + ")");
Log.err(str);
throw new Exception (str);
}
s.close();